//package com.ruoyi.system.websocket;
//
//import org.springframework.amqp.core.Binding;
//import org.springframework.amqp.core.BindingBuilder;
//import org.springframework.amqp.core.DirectExchange;
//import org.springframework.amqp.core.Queue;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class WebSocketRabbitConfig {
//
//    public static final String WEBSOCKET_EXCHANGE = "websocket.exchange";
//    public static final String WEBSOCKET_QUEUE = "websocket.payment.notification.queue";
//    public static final String WEBSOCKET_ROUTING_KEY = "websocket.payment.notification";
//
//    @Bean
//    public DirectExchange websocketExchange() {
//        return new DirectExchange(WEBSOCKET_EXCHANGE);
//    }
//
//    @Bean
//    public Queue websocketQueue() {
//        return new Queue(WEBSOCKET_QUEUE);
//    }
//
//    @Bean
//    public Binding websocketBinding() {
//        return BindingBuilder.bind(websocketQueue())
//                .to(websocketExchange())
//                .with(WEBSOCKET_ROUTING_KEY);
//    }
//}